package org.huatek.anders.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author anders
 * @date 2018-11-15 13:30
 * DirectExchange是RabbitMQ的默认交换机，直接使用routingKey匹配队列
 * 配置一个routingKey为notify.payment的消息队列
 **/
@Configuration
public class DirectConfig {
    @Bean
    public Queue paymentNotifyQueue() {
        return new Queue("notify.payment");
    }
    @Bean
    public Queue refundNotifyQueue() {
        return new Queue("notify.refund");
    }
}
